/*
package cn.rkylin.oms.dblog.listener;

import org.apache.commons.lang.SerializationUtils;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.core.MessageListener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.mongodb.core.MongoTemplate;

public class LogQueueListener implements MessageListener {

    @Autowired
    private MongoTemplate mongoTemplate;


    @Override
    public void onMessage(Message message) {
        Object wwb = SerializationUtils.deserialize(message.getBody());
        mongoTemplate.insert(wwb, "oms_log");
    }
}
*/
